package com.changanw.jedis.redisbloom;

import io.rebloom.client.Client;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import redis.clients.jedis.JedisPool;

/**
 * 布隆过滤器
 */
public class BoolmFilter {
    public static void main(String[] args) {
        GenericObjectPoolConfig config = new GenericObjectPoolConfig();
        //连接池最大空闲数量
        config.setMaxIdle(300);
        //最大连接数
        config.setMaxTotal(1000);
        //连接最大等待时间，如果是 -1 表示没有限制
        config.setMaxWaitMillis(30000);
        //在空闲时检查有效性
        config.setTestOnBorrow(true);
        /**
                 * 1. Redis 地址
                 * 2. Redis 端口
                 * 3. 连接超时时间
         **/
        JedisPool jedisPool = new JedisPool(config, "localhost", 6379, 30000);
        Client client = new Client(jedisPool);
        //存入数据
//        for (int i = 0; i < 100000; i++) {
//            client.add("name","changanw-"+i);
//        }
        //判断数据是否存在
        final boolean exists = client.exists("name", "changanw-99999");
        System.out.println(exists);

    }
}
